wget https://datax-opensource.oss-cn-hangzhou.aliyuncs.com/202309/datax.tar.gz
tar -zxvf datax.tar.gz -C /home/hadoop/bigdata/


# 测试

# 运行 DataX,在 DataX 的目录下，使用如下命令运行同步任务（mkdir src 将src下的json文件上传）：
python datax.py src/app_hism_movielens_movie_report2mysql.json


# Hive创建表
CREATE TABLE `hdp_lbg_supin_zplisting.app_hism_movielens_movie_report`(
    `genres_cnt` string COMMENT '电影的类别数',
    `dist_cnt` string COMMENT '分布情况'
)
COMMENT 'app层movielens电影movie_report统计信息'
PARTITIONED BY (`dt` string COMMENT '日期分区')
STORED AS TEXTFILE;


# Mysql创建测试SQL
CREATE TABLE `app_hism_movielens_movie_report` (
  `genres_cnt` varchar(255) default '',
  `dist_cnt` varchar(255) default ''
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC COMMENT='datax test';


